package com.mm.cloud.common.mq.message;

import lombok.Data;

import java.io.Serializable;

/**
 * 附加消息
 *
 * @author mr
 * @since 2021-09-15
 */
@Data
public class CustomMessage implements Serializable {

    private static final long serialVersionUID = 1L;

    /**
     * 消息ID
     */
    private String messageId;

    /**
     * 消息数据
     */
    private Object message;

    /**
     * 消息发送方IP TODO
     */
    private String ip = "";//IPUtils.getLocalIp();

    public CustomMessage(String messageId, Object message) {
        super();
        this.messageId = messageId;
        this.message = message;
    }

    public CustomMessage() {
        super();
    }
}
